package com.aliyun.messagemgt.application.service.mq;

import com.aliyun.messagemgt.application.service.RealTimeCountService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

/**
 * 消费者
 *
 * @author changcong
 */
@Component
public class MqConsumer implements InitializingBean {

    private static final Logger logger = LoggerFactory.getLogger(MqConsumer.class);
    //@Value("${MQ.rocket.topic}")
    private String topic;
    
    private static final String TAG = "MSG_RES";

    @Autowired
    private BusMqConfig busMqConfig;
    
    @Autowired
    private RealTimeCountService realTimeCountService;

/*    @Autowired
    private MonitorService monitorService;*/
    @Override
    public void afterPropertiesSet() throws Exception {
    }

}
